package com.example.flink;

import org.springframework.stereotype.Service;

@Service
public class FlinkJobService {

    public void startFlinkJob() throws Exception {
        FlinkConfig.configureFlinkStream();
    }
}
